d80ee71621b0308cd16d2f43bc098c2446d4dda3,clients/unshaded/src/test/java/tachyon/client/file/FileOutStreamTest.java,FileOutStreamTest,closeTest,#,193
Before Change
Assert.assertTrue(mTachyonOutStreamMap.get(streamIndex).isClosed());
}
Mockito.verify(mWorkerClient, Mockito.times(1)).persistFile(Mockito.eq(FILE_ID),
Mockito.anyLong(), Mockito.anyString());
Mockito.verify(mFileSystemMasterClient, Mockito.times(1)).completeFile(FILE_ID);
Mockito.verify(mBlockStoreContext, Mockito.timeout(1)).acquireWorkerClient();
Mockito.verify(mBlockStoreContext, Mockito.timeout(1)).releaseWorkerClient(mWorkerClient);
After Change
*/
@Test
public void closeTest() throws Exception {
Mockito.when(mUnderFileSystem.rename(Mockito.anyString(), Mockito.anyString()))
.thenReturn(true);
mTestStream.write(BufferUtils.getIncreasingByteArray((int) (BLOCK_LENGTH * 1.5)));
mTestStream.close();
for (long streamIndex = 0; streamIndex < 2; streamIndex ++) {
Assert.assertFalse(mTachyonOutStreamMap.get(streamIndex).isCanceled());
Assert.assertTrue(mTachyonOutStreamMap.get(streamIndex).isClosed());
}
Mockito.verify(mFileSystemMasterClient, Mockito.times(1)).completeFile(Mockito.eq(FILE_ID),
Mockito.any(CompleteFileOptions.class));
}
/**